package com.wsc.consumer.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 *  spring cloud stream input interface
 */
public interface Barista {

    String INPUT_CHANNEL = "input_channel";

    /**
     * 声明这是一个输入型的管道,名字是 Barista.INPUT_CHANNEL
     * @return
     */
    @Input(Barista.INPUT_CHANNEL)
    SubscribableChannel loginput();

}
